Skip to main content

BackgroundMqCollection<T>

Assembly: ServiceStack.dll​
View Source​
Declaration
public class BackgroundMqCollection<T> : IMqCollection, IDisposable

Properties​

ThreadCount​

View Source​
Declaration
public int ThreadCount { get; }

OutQMaxSize​

View Source​
Declaration
public int OutQMaxSize { get; set; }

QueueType​

View Source​
Declaration
public Type QueueType { get; }

MqClient​

View Source​
Declaration
public BackgroundMqClient MqClient { get; }

HandlerFactory​

View Source​
Declaration
public IMessageHandlerFactory HandlerFactory { get; }

Methods​

Add(String, IMessage)​

View Source​
Declaration
public void Add(string queueName, IMessage message)
Parameters​
TypeName
System.StringqueueName
ServiceStack.Messaging.IMessagemessage

TryTake(String, out IMessage)​

View Source​
Declaration
public bool TryTake(string queueName, out IMessage message)
Returns​

System.Boolean

Parameters​
TypeName
System.StringqueueName
ServiceStack.Messaging.IMessagemessage

TryTake(String, out IMessage, TimeSpan)​

View Source​
Declaration
public bool TryTake(string queueName, out IMessage message, TimeSpan timeout)
Returns​

System.Boolean

Parameters​
TypeName
System.StringqueueName
ServiceStack.Messaging.IMessagemessage
System.TimeSpantimeout

Clear(String)​

View Source​
Declaration
public void Clear(string queueName)
Parameters​
TypeName
System.StringqueueName

CreateWorker(String)​

View Source​
Declaration
public IMqWorker CreateWorker(string mqName)
Returns​

ServiceStack.Messaging.IMqWorker

Parameters​
TypeName
System.StringmqName

GetDescription()​

View Source​
Declaration
public string GetDescription()
Returns​

System.String

GetDescriptionMap()​

View Source​
Declaration
public Dictionary<string, long> GetDescriptionMap()
Returns​

System.Collections.Generic.Dictionary<System.String,System.Int64>

Dispose()​

View Source​
Declaration
public void Dispose()

Implements​